package com.dxf.bigdata.D05_spark_again.工程化代码.common

import com.dxf.bigdata.D05_spark_again.工程化代码.utils.EnvUtils
import org.apache.spark.SparkContext
import org.apache.spark.rdd.RDD

trait TDao {


  def readFile(path:String): RDD[String] = {
    val sc: SparkContext = EnvUtils.get()
    val lines: RDD[String] = sc.textFile(path)
    lines
  }


}
